package cc.spider.datapipe;


import cc.spider.core.IDataPipe;
import cc.spider.model.FlowData;

import java.util.Map;

public class SimpleDataPipe implements IDataPipe {
    @Override
    public boolean write(FlowData flowData) {
        System.out.println("dataPipe start");
        Map<String, Object> map = flowData.getFields();
        for (String key : map.keySet()) {
            System.out.println(key + ":" + map.get(key));
        }
        System.out.println("dataPipe end");
        return true;
    }
}
